package com.wenx.kafkacamel;

import org.apache.camel.Exchange;
import org.apache.camel.Processor;

public class ConsumerProcessor  implements Processor {

    public void process(Exchange exchange) throws Exception {
        System.out.println(exchange.getIn());
        System.out.println(000);
        System.out.println(exchange.getOut());
        System.out.println(111);
    }
}
